from celery import Celery

# 设置Django运行所需的配置环境
import os

if not os.environ.get("DJANGO_SETTINGS_MODULE"):
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.setting.dev")

# 1,创建Celery对象
celery_app = Celery("celery_tasts")

# 2,加载配置信息
celery_app.config_from_object('celery_tasks.config')

# 启动worker时自动监听任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])
